var ws = require("nodejs-websocket");

var server = ws.createServer(function (conn) {
  console.log("连接成功");
  //console.log()
  conn.on("text", function (str) {
    //conn.sendText(str);
    console.log("服务端接受消息", str)
    //boardcast(str);


    // setInterval(() => {
    //   conn.sendText('{"type":"PING","data":"我是心跳反馈"}');
    // }, 3000)
    setInterval(() => {
      conn.sendText('{"type":"DICTIONARY","data":"数据字典更新"}');
    }, 6000)

    let strObj = JSON.parse(str);
    console.log("strObj", strObj)
    if (strObj.type === "ping") {
      console.log("走ping")
      conn.sendText('{"type":"PING","data":"我是心跳反馈"}');
    } else {
      boardcast(str);
    }
  })
  // setTimeout(function () {
  //   conn.sendText("来自客户端的消息");
  // }, 5000)

  //连接关闭
  conn.on("close", function (err) {
    console.log("连接关闭", err)
    conn && conn.sendText("连接-close");
  })

  //处理断开连接的错误捕获
  conn.on("error", function (err) {
    console.log("连接error", err)
    conn && conn.sendText("连接-error");
  })
}).listen(2333)

function boardcast(str) {
  server.connections.forEach(function (conn) {
    conn.sendText(str);
  })
}